//package com.gaofei.dofile.consumer;
//
//import org.apache.kafka.clients.consumer.ConsumerRecord;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.kafka.support.Acknowledgment;
//import org.springframework.stereotype.Component;
//
//@Component
//public class KafkaLisenner {
//
//    @KafkaListener(topics = "gaofee" ,containerFactory="ackContainerFactory")
//    public void revMsg(ConsumerRecord<String, String> msgObject, Acknowledgment ack ){
//        System.out.println(msgObject.value());
//
//
//        //消息确认
//        ack.acknowledge();
//    }
//}
